//npm install nodejs-websocket

var ws = require('nodejs-websocket');
var port=3000
var server = ws.createServer(function(conn){
	//连接时触发//
	console.log('new connection');
	
	conn.on("text",function(str){
			// 收到信息触发     接收 //
			console.log("received："+str)
			
			// 广播消息 //
			// boardcast(str) 
			
			// 发送 消息 //
			conn.sendText("服务器已收到消息：" +  str) 
	})
	
	// 断开连接触发 //
	conn.on("close",function(code,reason){
			console.log("connection closed")
	})
	
	// 出错触发 //
	conn.on("error",function(err){
			
			console.log("header err")
			console.log(err)
	})
	
	 // 广播 //
	function boardcast(str){
		//server.connections 每个连接进来的用户 //
		server.connections.forEach(function(conn){   //  .forEach 是调用数组里每个元素  //
			conn.sendText(str)
		})
	}
}).listen(port)
console.log("websocket server listen port is" + port)